package com.jf.concurrent.queue.disruptor.demo;

import com.jf.concurrent.queue.disruptor.model.MessageModel;
import com.jf.concurrent.queue.disruptor.producer.MessageEventProducer;
import com.lmax.disruptor.RingBuffer;

public class Main {
    public static void main(String[] args) {
	final RingBuffer<MessageModel> ringBuffer = MQManager.buidldRingBuffer();
	final MessageEventProducer eventProducer = new MessageEventProducer(ringBuffer);
	eventProducer.buildMessage("Hello Disruptor!");


    }
}
